package com.fanxuankai.boot.canal.listener.autoconfigure;

import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * @author fanxuankai
 */
@ConfigurationProperties(prefix = CanalListenerProperties.PREFIX)
public class CanalListenerProperties {
    public static final String PREFIX = "fxk.canal.listener";
    public static final String ENABLED = PREFIX + ".enabled";
    /**
     * 是否开启 canal listener，开启后自动创建 MQ 的监听器
     */
    private boolean enabled = true;
    /**
     * 全局数据库名称
     * <p>
     * 获取数据库名称的步骤, 先后顺序如下:<p>
     * CanalTable.schema()<p>
     * javax.persistence.Table.schema()<p>
     * 全局数据库名称<p>
     * 若始终无法获取到数据库名称, 程序终止, 抛出异常
     */
    private String globalSchema;

    public boolean isEnabled() {
        return enabled;
    }

    public void setEnabled(boolean enabled) {
        this.enabled = enabled;
    }

    public String getGlobalSchema() {
        return globalSchema;
    }

    public void setGlobalSchema(String globalSchema) {
        this.globalSchema = globalSchema;
    }
}
